261cb3577d094c3c3a3cf74829e84608249b4034,src/main/java/com/continuuity/data/operation/ttqueue/TTQueueNewOnVCTable.java,TTQueueNewOnVCTable,unack,#QueueEntryPointer#QueueConsumer#ReadPointer#,340

Before Change


      new byte[][] {new EntryConsumerMeta(EntryConsumerMeta.EntryState.CLAIMED, 0).getBytes(),
                                                         Bytes.toBytes(entryPointer.getEntryId()), Bytes.toBytes(0)});
    if(consumer.isStateful()) {
      getQueueStateImpl(consumer.getQueueState()).setActiveEntryId(entryPointer.getEntryId());
    }
  }
  static long groupId = 0;

After Change


    }

    // Set unack state
    queueState.setActiveEntryId(entryPointer.getEntryId());
    queueState.setActiveEntryTries(0);

    // Write unack state